home *** CD-ROM | disk | FTP | other *** search
/ AOL File Library: 2,801 to 2,900 / aol-file-protocol-4400-2801-to-2900.zip / AOLDLs / C++ Files Library / SK (Sockects) 1.4.1 r2 / SK v1.4.1 r2.sit / SK 1.4.1 r2 / SK / SK Sources / SK_Buffer.cc next >
Text File  |  1994-06-13  |  6KB  |  245 lines
  1. /***************************************************************************
  2. * 
  3. * 
  4. * Copyright ⌐ 1992-1994 Matthias Neeracher and the Decision Systems Group
  5. * 
  6. * Permission is granted to anyone to use this software for any purpose on
  7. * any computer system, and to redistribute it freely, subject to the
  8. * following restrictions:
  9. * 
  10. * 1) The authors and the Decision Systems Group are not responsible for 
  11. *    the direct or indirect consequences of use of this software, no matter 
  12. *    how awful, even if they arise from defects in the software itself.
  13. *    This restriction applies to the use of this and any derived source code 
  14. *    and also to the use of all binary produced from this and any derived 
  15. *    source code.
  16. * 2) The origin and copyrights of this software must not be misrepresented, 
  17. *    either by explicit claim or by omission or alteration of copyright or
  18. *    authorship header information in this file or in any derived file.
  19. * 3) Altered or derived versions must be plainly marked as such, and must not
  20. *    be misrepresented as being the original software.
  21. * 
  22. * We encourage users of this software to provide feedback, bug fixes,
  23. * and enhancements to the authors for incorporation into future releases.
  24. *
  25. * ==========================================================================
  26. * 
  27. * FILE: SK_Buffer.cc
  28. * 
  29. * AUTHOR: Matthias Neeracher and Stephan Deibel
  30. * 
  31. * CREATION DATE: 01Aug92
  32. * 
  33. * VERSION: 13Jun94
  34. * 
  35. * DESCRIPTION: 
  36. * 
  37. * Scatterer/Gatherer (Producer/Consumer) classes for SK buffering
  38. * 
  39. * NOTES: 
  40. * 
  41. * 0) This code was derived from Matthias Neerarcher's GUSI 1.1.0; Copyrights
  42. *    are subject to that fact.
  43. *
  44. * MODIFICATIONS: 
  45. * --------------------------------------------------------------------------
  46. * Date     Name      Description of modification
  47. * --------------------------------------------------------------------------
  48. * 
  49. * 02Aug92   MN       SKt_Deferred procedures
  50. * 23Aug92    MN       Optimize buffer size for empty buffers
  51. * 10Feb93    MN       The above was incorrect, next attempt
  52. * 13Jul93    SD       Port to THINK C++ 6.0
  53. * 21Jul93    SD       Subsetted to only TCP/UDP, applied DSG naming 
  54. *                    conventions and commenting guidlines, and
  55. *                    changed name to "SK" for clear distinction from
  56. *                    the GUSI code from which this was derived
  57. * 13Jun94   SD       Updated based on relevant changes to GUSI (through 1.4.1)
  58. * 
  59. */
  60.  
  61. #ifndef SK_BUFFER_DEBUG
  62. #define NDEBUG
  63. #endif
  64.  
  65. #include "SK_P.hh"
  66.  
  67.  
  68.  
  69. /**************************************************************************/ 
  70. /* Scatter/Gather Generic Class */
  71.  
  72.  
  73. /****************************************************************************
  74. * FUNCTION:
  75. *
  76. * CSK_ScattGath::CSK_ScattGath()
  77. *
  78. * DESCRIPTION:
  79. *
  80. * Constructor for scatterer/gatherer generic class
  81. *
  82. * PARAMETERS:
  83. *
  84. * struct iovec *        -- I/O vector
  85. * int                     -- Count
  86. *
  87. */
  88.  
  89. CSK_ScattGath::CSK_ScattGath(const struct iovec *iov, int cnt)    
  90. {
  91.     fIOVector        =    iov;
  92.     fCount    =    cnt;
  93.  
  94.     if (fCount < 1)    {
  95.         fBuffer        =    nil;
  96.         fLength        =    0;
  97.         fScratchHandle    =    nil;
  98.     } else if (fCount == 1)    {    
  99.         fBuffer        =    (void *) iov->iov_base;
  100.         fLength        =    (int)    iov->iov_len;
  101.         fScratchHandle    =    nil;
  102.     } else {
  103.         for (fLength = 0; fCount--; ++iov)
  104.             fLength += (int) iov->iov_len;
  105.         
  106.         fScratchHandle = NewHandle(fLength);
  107.         
  108.         if (fScratchHandle)    {
  109.             MoveHHi(fScratchHandle);
  110.             HLock(fScratchHandle);
  111.             fBuffer    = (void *) *fScratchHandle;
  112.         } else
  113.             fBuffer = nil;
  114.     }
  115. }
  116.  
  117.  
  118. /****************************************************************************
  119. * FUNCTION:
  120. *
  121. * CSK_ScattGath::~CSK_ScattGath()
  122. *
  123. * DESCRIPTION:
  124. *
  125. * Destructor for scatterer/gatherer generic class
  126. *
  127. */
  128.  
  129. CSK_ScattGath::~CSK_ScattGath()
  130. {
  131.     if (fScratchHandle) {
  132.         HUnlock(fScratchHandle);
  133.         fBuffer = nil;
  134.         DisposHandle(fScratchHandle);
  135.         }
  136. }
  137.  
  138.  
  139.  
  140. /**************************************************************************/ 
  141. /* Scatterer Class */
  142.  
  143.  
  144. /*************************************************************************** *
  145. * FUNCTION:
  146. *
  147. * CSK_Scatterer::CSK_Scatterer()
  148. *
  149. * DESCRIPTION:
  150. *
  151. * Constructor for scatterer class
  152. *
  153. * PARAMETERS:
  154. *
  155. * struct iovec *        -- I/O vector
  156. * int                     -- Count
  157. *
  158. */
  159.  
  160.  
  161. CSK_Scatterer::CSK_Scatterer(const struct iovec *iov, int count) 
  162.     : CSK_ScattGath(iov, count)
  163. {
  164. }
  165.  
  166.  
  167. /****************************************************************************
  168. * FUNCTION:
  169. *
  170. * CSK_Scatterer::~CSK_Scatterer()
  171. *
  172. * DESCRIPTION:
  173. *
  174. * Destructor for scatterer class
  175. *
  176. */
  177.  
  178. CSK_Scatterer::~CSK_Scatterer()
  179. {
  180.     int    sect;
  181.     
  182.     if (fCount > 1 && fBuffer)
  183.         for (char * bptr = (char *) fBuffer; fCount-- && fLength; ++fIOVector)    {
  184.             sect = MIN(fLength, fIOVector->iov_len);
  185.             
  186.             memcpy(fIOVector->iov_base, bptr, sect);
  187.             
  188.             bptr += sect;
  189.             fLength -= sect;
  190.         }
  191. }
  192.  
  193.  
  194.  
  195.  
  196. /**************************************************************************/ 
  197. /* Gatherer Class */
  198.  
  199.  
  200. /*************************************************************************** *
  201. * FUNCTION:
  202. *
  203. * CK_Gatherer::CK_Gatherer()
  204. *
  205. * DESCRIPTION:
  206. *
  207. * Constructor for gatherer class
  208. *
  209. * PARAMETERS:
  210. *
  211. * struct iovec *        -- I/O vector
  212. * int                     -- Count
  213. *
  214. */
  215.  
  216.  
  217. CK_Gatherer::CK_Gatherer(const struct iovec *iov, int count) 
  218.     : CSK_ScattGath(iov, count)
  219. {
  220.     if (fCount > 1 && fBuffer)
  221.         for (char * bptr = (char *) fBuffer; fCount--; ++iov)    {
  222.             memcpy(bptr, iov->iov_base, iov->iov_len);
  223.             
  224.             bptr += iov->iov_len;
  225.         }
  226. }
  227.  
  228.  
  229. /****************************************************************************
  230. * FUNCTION:
  231. *
  232. * CK_Gatherer::~CK_Gatherer()
  233. *
  234. * DESCRIPTION:
  235. *
  236. * Destructor for gatherer class
  237. *
  238. */
  239.  
  240. CK_Gatherer::~CK_Gatherer()
  241. {
  242. }
  243.  
  244.  
  245.